from celery import Celery
import os
#加载配置文件
#2 celery 可以单独运行
#我们celery 用到了django的配置信息，所以我们要在这里加载django 的配置信息

if not os.getenv('DJANGO_SETTINGS_MODULE'):
    os.environ['DJANGO_SETTINGS_MODULE'] = 'mall.settings'



#创建celery对象
#参数main设置脚本名
#main 是celery 的第一个参数 ，习惯上用脚本的名字
app = Celery('celery_tasks')


#3设置broker
app.config_from_object('celery_tasks.config')


#4让worker 去执行
#我们需要 在celery 的脚本路径中执行指令
#而且是需要 虚拟环境中执行
app.autodiscover_tasks(['celery_tasks.sms','celery_tasks.email'])


